require_relative '../lib/kafka_client'

require 'byebug'

byebug
KafkaClient.receive_message do |message|
  puts message.value
end

# require "kafka"
# kafka = Kafka.new(["localhost:9092"])
# kafka.each_message(topic: "test") do |message|
#   puts message.offset, message.key, message.value
# end
